package com.hex.ds.hdtp.core.inf.data.contrast.repository;

import com.hex.ds.hdtp.core.inf.common.page.Page;
import com.hex.ds.hdtp.core.inf.common.repository.IBasicRepository;
import com.hex.ds.hdtp.core.inf.data.contrast.po.CrossDbContrastRunLogPo;

import java.util.List;

/**
 * @Package: com.hex.ds.hdtp.core.inf.data.contrast.repository
 * @ClassName ICrossDbContrastRunLogRepository
 * @Description: 跨库比对记录-数据接口
 * @Author: wz.li
 * @Date 2023/7/25 18:55
 * @Version v2.0.2
 **/
public interface ICrossDbContrastRunLogRepository extends IBasicRepository<CrossDbContrastRunLogPo> {

    Page<CrossDbContrastRunLogPo> queryListByPage(CrossDbContrastRunLogPo crossDbContrastRunLogPo, Page toPage);

    List<CrossDbContrastRunLogPo> queryByTaskIdStatus(String taskPkId, String status);

    void modifySuccessNum(String pkId);

    void modifyFailNum(String pkId);

    void modifyStatus(String pkId);

    /**
     * 停止比对任务
     *
     * @param pkId
     * @param status
     * @return
     */
    Integer modifyStopTask(String pkId, String status);
    /*
     * @param pkId:
     * @return String
     * @author Liang Fuhao
     * @description 根据id查状态
     * @date 2024/1/15 11:03
     */
    String queryStatusByPkId(String pkId);
}
